package org.easy.kafka.utils;

import java.io.IOException;

import kafka.serializer.Encoder;

/**
 * 
 */
public class ObjectEncoder implements Encoder<Object>{

	@Override
	public byte[] toBytes(Object object) {
		byte[] b = null;
		try {
			b = ConvertUtils.Byte.toBytes(object);
		} catch (IOException e) {
		}
		
		return b;
	}
}
